/*
 * Copyright 2020-2025 the original author or authors.
 * You cannot use this file unless authorized by the author.
 */

package org.ipig.commons.conf.rocket.producer;

import lombok.Data;
import lombok.ToString;

import java.io.Serializable;

/**
 * RocketMq生产者配置属性
 *
 * @author <a href="mailto:comchnts@163.com">chinats</a>
 * @version $$Id: RocketProducerConf.java 3 2020-01-21 09:36:33Z ts <comchnts@163.com> $$
 * @since 1.0
 */
@Data
@ToString
public class RocketProducerConf implements Serializable {
    // nameserver地址
    private String namesrvAddr = "";
    // instance名称
    private String instanceName = "";
    // 消费群组
    private String group = "";
    // 队列数量
    private int queueNums = 4;
    // 发送消息超时时间
    private int timeout = 3000;
    // 消息主题
    private String dufaultTopic = "";
    //* 消息标签，只支持设置一个Tag（服务端消息过滤使用）
    private String dufaultTags = "";
    // 消息关键词，多个Key用KEY_SEPARATOR隔开（查询消息使用）
    private String dufaultKeys = "";
    //默认大小128K,这里设置最大256K
    private int maxMessageSize = 131072 * 2;
}
